// package ai.mspbots.service.projectd.listener;
//
// import ai.mspbots.service.projectd.consumer.MessageConsumer;
// import org.springframework.boot.CommandLineRunner;
//
// public class Listener implements CommandLineRunner {
//
//     private static final String topicName = "test-trace-topic";
//     @Override
//     public void run(String... args) throws Exception {
//         String bootstrapServers = System.getProperty("bootstrap.servers", "127.0.0.1:9092");
//         new MessageConsumer(bootstrapServers, topicName).start();
//         Thread.currentThread().join();
//     }
// }
